4360e2b06c47128b318379a1e3726dbae3845080,src/test/java/io/confluent/connect/hdfs/avro/DataWriterAvroTest.java,DataWriterAvroTest,testProjectForward,#,461

Before Change


    hdfsWriter.write(sinkRecords);
    hdfsWriter.close();

    path = new Path(FileUtils.committedFileName(url, topicsDir, DIRECTORY, TOPIC_PARTITION, 2L,
                                                2L, extension, ZERO_PAD_FMT));
    records = (ArrayList<Object>) schemaFileReader.readData(conf, path);
    assertEquals(1, records.size());

After Change



    assertEquals(avroData.fromConnectData(newSchema, newRecord), records.get(0));

    path = new Path(FileUtils.committedFileName(url, topicsDir, DIRECTORY, TOPIC_PARTITION, 1L,
                                                2L, extension, ZERO_PAD_FMT));
    records = (ArrayList<Object>) schemaFileReader.readData(conf, path);
    assertEquals(avroData.fromConnectData(schema, record), records.get(0));
    assertEquals(avroData.fromConnectData(schema, record), records.get(1));